/*
 * Copyright (C) 2005 Johan Maasing johan at zoom.nu Licensed under the Apache
 * License, Version 2.0 (the "License"); you may not use this file except in
 * compliance with the License. You may obtain a copy of the License at
 * http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law
 * or agreed to in writing, software distributed under the License is
 * distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied. See the License for the specific language
 * governing permissions and limitations under the License.
 */
package nu.zoom.swing.desktop.worker;

import nu.zoom.swing.text.ConsoleBean;

/**
 * 
 * @author $Author$
 * @version $Revision$
 * 
 */
public class BlockingImpl implements Blocking {
	private ConsoleBean console;

	/**
	 * 
	 */
	public BlockingImpl(ConsoleBean console) {
		super();
		this.console = console;
	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see nu.zoom.swing.desktop.worker.TestBlocking#threadBlock()
	 */
	public String threadBlock() {
		console.info(this + " String threadBlock " + Thread.currentThread()
				+ "\n");
		sleep();
		console.info("Calling eventQueueBlock\n") ;
		return "" + eventQueueBlock();
	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see nu.zoom.swing.desktop.worker.TestBlocking#threadException()
	 */
	public void threadException() throws Exception {
		console.info(this + "threadException" + Thread.currentThread() + "\n");
		sleep();
		throw new Exception();

	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see nu.zoom.swing.desktop.worker.TestBlocking#eventQueueBlock()
	 */
	public String eventQueueBlock() {
		console.info(this + " String eventQueueBlock " + Thread.currentThread()
				+ "\n");
		sleep();
		return "" + this ;
	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see nu.zoom.swing.desktop.worker.TestBlocking#eventQueueException()
	 */
	public void eventQueueException() throws Exception {
		console.info(this + "eventQueueException" + Thread.currentThread()
				+ "\n");
		sleep();
		throw new Exception();

	}

	private void sleep() {
		console.warn("Sleeping...\n");
		try {
			Thread.sleep(500);
		} catch (InterruptedException e) {
		}
	}

}
